package com.xbongbong.workflow.binders;

import com.xbongbong.workflow.constant.WorkflowMqProducerConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

/**
 * workflow 消息队列
 * @author 魏荣杰
 *
 */
@Service("workflowMqProducerBinder")
public interface WorkflowMqProducerBinder {

//    @Input(WorkflowMqProducerConstant.WORKFLOW_START_INPUT)
//    SubscribableChannel workflowStartInput();
    @Output(WorkflowMqProducerConstant.WORKFLOW_START_OUTPUT)
    MessageChannel workflowStartOutput();

//    @Input(WorkflowMqProducerConstant.WORKFLOW_OPERATOR_INPUT)
//    SubscribableChannel workflowOperatorInput();

    @Output(WorkflowMqProducerConstant.WORKFLOW_OPERATOR_OUTPUT)
    MessageChannel workflowOperatorOutput();
    /**
     * 工作流无审批 消费者
     * @return
     */
//    @Input(WorkflowMqProducerConstant.WORKFLOW_OPERATOR_NO_APPROVE_INPUT)
//    MessageChannel workflowOperatorNoApproveInput();
    /**
     * 工作流无审批 生产者
     * @return
     */
    @Output(WorkflowMqProducerConstant.WORKFLOW_OPERATOR_NO_APPROVE_OUTPUT)
    MessageChannel workflowOperatorNoApproveOutput();
}
